<?php

// function sendToUser($url, $message)
// {
//     print_r($url);
//     print_r($message);
//     $ch = curl_init();
//     curl_setopt($ch, CURLOPT_URL, $url);
//     curl_setopt($ch, CURLOPT_HEADER, 0);
//     curl_setopt($ch, CURLOPT_POST, 1);
//     curl_setopt($ch, CURLOPT_POSTFIELDS, $message);
//     $data = curl_exec($ch);
//     if($errno = curl_errno($ch)) {
//         $error_message = curl_strerror($errno);
//         echo "cURL error ({$errno}):\n {$error_message}";
//     }
//     curl_close($ch);
//     var_dump($data);
// }

// sendToUser("http://front.yyuexs.com/api/kefu", ['user_id' =>108557, 'message' => '564f564as6df46a4']);
// return;

    // 建立socket连接到内部推送端口
    $client = stream_socket_client('tcp://192.168.10.10:5678', $errno, $errmsg, 1);
    // 推送的数据，包含uid字段，表示是给这个uid推送

//for($i = 1; $i < 20; $i++){
    $userinfo = [
        'user_id' => 108557,
        'content' => '89',
        'nickname' => 'ddd',
        'avatar'=> 'http://lorempixel.com/38/38/?7f00000108fc00000005',
        'wechat_id' => 1,
        'admin_id'=>112,
        'appid' => 1,
        'wechat_name' => '测试公众号',
        'channel' => 'cps',
    ];

    // $data = array('uid'=>'uid1', 'percent'=>'88%');
    // 发送数据，注意5678端口是Text协议的端口，Text协议需要在数据末尾加上换行符
    fwrite($client, json_encode($userinfo)."\n");
    // 读取推送结果
    echo fread($client, 8192);
//}
$data = ['memory' => 1];
fwrite($client, json_encode($data)."\n");
echo fread($client, 8192);
fclose($client);